/**
 * 
 */
package com.zte.claa.inficombo.csa.app.service.mqttproxy;

import java.util.Set;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author 0283000115
 * 
 * MQTT设备对接代理接口
 */
public interface IMqttProxyService {
	// 支持的设备类型.
	public Set<String> getSupportDevtypes();
	
	// 上报数据。
	public void onDataReport(String topic, MqttMessage msg);
	
	// 下行命令分发.
	public int sendControlCmd(String cmd) throws Exception; 
	
	// 重新初始化.
	public void reInitService() throws Exception;
}
